/**
 * 所需 npm 包：ws
 */

const WebSocket = require('ws');

// 创建 WebSocket 服务器
const wss = new WebSocket.Server({ port: 7070 });

// 当有新的连接建立时触发
wss.on('connection', function connection(ws) {
  console.log('WebSocket 连接已建立');

  // 当接收到消息时:默认类型为 Buffer ，需要手动转换为 string
  ws.on('message', function incoming(message) {
    let data = message.toString('utf8');
    console.log('data:', data);
    ws.send(data);
  });

  // 当连接关闭时
  ws.on('close', function close() {
    console.log('WebSocket 连接断开');
  });
});
